package com.aqiang.net;

import android.util.Log;

import io.reactivex.observers.DisposableObserver;

public abstract class BaseObserver<T> extends DisposableObserver<T> implements IObserver<T> {
    @Override
    public void onNext(T t) {
        ok(t);
    }

    @Override
    public void onError(Throwable e) {
        no(e.getMessage());
    }

    @Override
    public void onComplete() {

    }

    @Override
    public void no(String msg) {
        Log.d("swq", "no: "+msg);
    }
}
